// TODO
//  统计一座城市所有人(10万或100万)某一天的平均消费水平。
//  假设这些信息都存储在一个文件里，并且该文件的格式如下，第一列是ID，第二列是性别，第三列是每天消费额。


import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object 上机02 {
  def main(args: Array[String]): Unit = {

    val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("")

    val sc = new SparkContext(config)

    val rddIn: RDD[Float] = sc.textFile("in/02.txt").map(_.split(",")).map(_ (2).toFloat)

    val avg: Double = rddIn.sum() / rddIn.count()

    println(avg)

  }

}
